package com.lsp.test.kafka.serializer;

import org.apache.kafka.common.serialization.Serializer;

public class ProtobufSerializer  implements Serializer<Protobufable> {
    @Override
    public byte[] serialize(String s, Protobufable protobufable) {
        return protobufable.encode();
    }
}
